package com.sluggard.ai.service;

import com.sluggard.ai.model.req.ChatReq;
import reactor.core.publisher.Flux;

import java.util.concurrent.ExecutionException;

/**
 * 类描述：
 *
 * @author lizheng
 * @created 2025/4/22 16:47
 */
public interface ChatService {

    Flux<String> chatStream(ChatReq chatReq) throws ExecutionException, InterruptedException;

}
